package kafka.springboot ;

import java.util.Optional ;

import org.apache.kafka.clients.consumer.ConsumerRecord ;
import org.springframework.kafka.annotation.KafkaListener ;

/**
 * kafka客户端接受消息监听类
 * @author 80002165 @date 2017年6月23日 下午5:41:27
 */
public class ConsumerListener {
    @KafkaListener(topics = { "test-topic" })
    public void listener(ConsumerRecord<?, ?> record) {
        Optional<?> kafkaMessage = Optional.ofNullable(record.value()) ;
        if (kafkaMessage.isPresent()) {
            Object message = kafkaMessage.get() ;
            System.out.println("listen:" + message) ;
        }
    }
}
